package cron

import (
	"context"
	"k8s.io/apimachinery/pkg/util/wait"
	"time"
)

// 定时同步ESC资源
func (cm *CronManager) SyncCloudResourceManager(ctx context.Context) error {
	// 每隔 多长时间去执行一下 RunSyncCloudResource ，直到 ctx.Done
	go wait.UntilWithContext(ctx, cm.RunSyncCloudResource, time.Duration(cm.Sc.PublicCloudSyncC.RunIntervalSeconds)*time.Second)
	<-ctx.Done()
	cm.Sc.Logger.Info("SyncCloudResourceManager收到其他任务退出信号 退出")
	return nil
}
func (cm *CronManager) RunSyncCloudResource(ctx context.Context) {
	cm.Sc.Logger.Info("模拟同步公有云资源中....")
	go cm.RunSyncCloudResourceEcs(ctx)
	go cm.RunSyncCloudResourceElb(ctx)
	go cm.RunSyncCloudResourceRds(ctx)

}
